package cn.boat.router.consumer;

import org.apache.zookeeper.ZooKeeper;

public interface SubscribeTopcisInterface  {
    ConsumerMetaData subscribeTopics(ZooKeeper zooKeeperConnection, String consumerGroupId, String consumerID, String topic) throws Exception;
    ConsumerMetaData subscribeTopics(ZooKeeper zooKeeperConnection, String consumerGroupId, String consumerID, String topic, int partitionQuantity) throws Exception;
}
